package com.shux.kafka.consumer;

import org.apache.kafka.common.serialization.Deserializer;

/**
 * 描述：
 * 
 * <pre>HISTORY
 * ****************************************************************************
 *  ID   DATE           PERSON          REASON
 *  1    2017年9月26日      Simba.Hua         Create
 * ****************************************************************************
 * </pre>
 * @author Simba.Hua
 */
public class NoTransactionalKafkaConsumer<T> extends ShuxKafkaConsumer<T> {

	public NoTransactionalKafkaConsumer(ConsumerConfig consumerConfig,
			ConsumerOptionConfig optionConfig,
			IMessageListener<T> messageListener, Deserializer<T> deserializer) {
		super(consumerConfig, optionConfig, messageListener, deserializer);
		// TODO Auto-generated constructor stub
	}

	@Override
	protected void beforeAddPackMessageToQueue(KafkaBatchMessage<T> batchMessage) {
		// TODO Auto-generated method stub
		
	}

}
